package main

import (
	"gim/mq"
	"gim/comm"
)

func main() {
	rmq := mq.NewRedisMQ("127.0.0.1:6379", "")
	
	msg := new(comm.Message)
	msg.Cmd = comm.MSG_IM
	msg.Seq = comm.CurrentTimeMillis()
	msg.Version = comm.DEFAULT_VERSION
	msg.Body = &comm.IMMessage{
		Sender : 1,
		Receiver : 2,
		Content : "hello 2! kitty ni",
		Extra : "nice job no noe",
	}
	
	rmq.Enqueue("GIM_MS_Q", msg)
}